b6dc7b26a5446f1fb1d83b4f9584896dce0ee726,PayvmentDemo/src/main/java/com/payvment/continuuity/ProductFeedFlow.java,ProductProcessorFlowlet,initialize,#,89
Before Change
@Override
public void initialize() {
this.productTable = new ProductTable(getFlowletContext().getDataFabric(),
getFlowletContext());
this.productUpdateCountTable = new CounterTable("productUpdates",
getFlowletContext().getDataFabric(), getFlowletContext());
this.allTimeScoreTable = new CounterTable("allTimeScores",
getFlowletContext().getDataFabric(), getFlowletContext());
this.topScoreTable = new SortedCounterTable("topScores",
After Change
@Override
public void initialize() {
this.productTable = new ProductTable();
getFlowletContext().getDataSetRegistry().registerDataSet(
this.productTable);
this.productUpdateCountTable = new CounterTable("productUpdates");
getFlowletContext().getDataSetRegistry().registerDataSet(
this.productUpdateCountTable);
this.allTimeScoreTable = new CounterTable("allTimeScores");
getFlowletContext().getDataSetRegistry().registerDataSet(
this.allTimeScoreTable);